Node / meshtastic / Meshtastic-Android / files / core / network / src / androidMain / kotlin / org / meshtastic / core / network / repository / SerialConnectionImpl.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tf0883e@fileTb4b4b4:Te6edf3SuppressTb4b4b4(Ta5d6ff"Ta5d6ffMagicNumberTa5d6ff"Tb4b4b4)

Tff7b72package T7ee787org.meshtastic.core.network.repository

Tff7b72import T7ee787android.hardware.usb.UsbManager

Tff7b72import T7ee787co.touchlab.kermit.Logger

Tff7b72import T7ee787com.hoho.android.usbserial.driver.UsbSerialDriver

Tff7b72import T7ee787com.hoho.android.usbserial.driver.UsbSerialPort

Tff7b72import T7ee787com.hoho.android.usbserial.util.SerialInputOutputManager

Tff7b72import T7ee787org.meshtastic.core.common.util.ignoreException

Tff7b72import T7ee787java.nio.BufferOverflowException

Tff7b72import T7ee787java.util.concurrent.CountDownLatch

Tff7b72import T7ee787java.util.concurrent.TimeUnit

Tff7b72import T7ee787java.util.concurrent.atomic.AtomicBoolean

Tff7b72import T7ee787java.util.concurrent.atomic.AtomicReference

Tff7b72internal Tff7b72class T56d364SerialConnectionImplTb4b4b4(

Tff7b72private Tff7b72val Te6edf3usbManagerLazyTb4b4b4: Te6edf3LazyTff7b72<Te6edf3UsbManager?Tff7b72>Tb4b4b4,

Tff7b72private Tff7b72val Te6edf3deviceTb4b4b4: Te6edf3UsbSerialDriverTb4b4b4,

Tff7b72private Tff7b72val Te6edf3listenerTb4b4b4: Te6edf3SerialConnectionListenerTb4b4b4,

Tb4b4b4) Tb4b4b4: Te6edf3SerialConnection Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3port Tff7b72= Te6edf3deviceTb4b4b4.Te6edf3portsTff7b72[T79c0ff0Tff7b72] T8b949e// Most devices have just one port (port 0)

Tff7b72private Tff7b72val Te6edf3closedLatch Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3closed Tff7b72= Te6edf3AtomicBooleanTb4b4b4(Tff7b72falseTb4b4b4)

Tff7b72private Tff7b72val Te6edf3ioRef Tff7b72= Te6edf3AtomicReferenceTff7b72<Te6edf3SerialInputOutputManagerTff7b72>Tb4b4b4(Tb4b4b4)

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooGenericExceptionCaughtTa5d6ff"Tb4b4b4)

Tff7b72override Tff7b72fun Td2a8ffsendBytesTb4b4b4(Te6edf3bytesTb4b4b4: Te6edf3ByteArrayTb4b4b4) Tb4b4b4{

Te6edf3ioRefTb4b4b4.Te6edf3getTb4b4b4(Tb4b4b4)Tff7b72?.Te6edf3let Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffwriting Tffd700${Te6edf3bytesTb4b4b4.Te6edf3sizeTffd700}Ta5d6ff byte(s)Ta5d6ff" Tb4b4b4}

Tff7b72try Tb4b4b4{

Tffa657itTb4b4b4.Te6edf3writeAsyncTb4b4b4(Te6edf3bytesTb4b4b4)

Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3eTb4b4b4: Te6edf3BufferOverflowExceptionTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3wTb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffBuffer overflow while writing to serial portTa5d6ff" Tb4b4b4}

Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3eTb4b4b4: Te6edf3ExceptionTb4b4b4) Tb4b4b4{

T8b949e// USB disconnections often cause IOExceptions here; log as warning to avoid Crashlytics noise

Te6edf3LoggerTb4b4b4.Te6edf3wTb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffFailed to write to serial port (likely disconnected)Ta5d6ff" Tb4b4b4}

Tb4b4b4}

Tb4b4b4}

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffcloseTb4b4b4(Te6edf3waitForStoppedTb4b4b4: Tffa657BooleanTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3closedTb4b4b4.Te6edf3compareAndSetTb4b4b4(Tff7b72falseTb4b4b4, Tff7b72trueTb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3ignoreExceptionTb4b4b4(Te6edf3silent Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4{ Te6edf3ioRefTb4b4b4.Te6edf3getTb4b4b4(Tb4b4b4)Tff7b72?.Te6edf3stopTb4b4b4(Tb4b4b4) Tb4b4b4}

Te6edf3ignoreExceptionTb4b4b4(Te6edf3silent Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4{

Te6edf3portTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4) T8b949e// This will cause the reader thread to exit

Tb4b4b4}

Tb4b4b4}

T8b949e// Allow a short amount of time for the manager to quit (so the port can be cleanly closed)

Tff7b72if Tb4b4b4(Te6edf3waitForStoppedTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffWaiting for USB manager to stop...Ta5d6ff" Tb4b4b4}

Te6edf3ignoreExceptionTb4b4b4(Te6edf3silent Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4{ Te6edf3closedLatchTb4b4b4.Te6edf3awaitTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4) Tb4b4b4}

Tb4b4b4}

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffcloseTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3closeTb4b4b4(Tff7b72trueTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffconnectTb4b4b4(Tb4b4b4) Tb4b4b4{

T8b949e// We shouldn't be able to get this far without a USB subsystem so explode if that isn't true

Tff7b72val Te6edf3usbManager Tff7b72= Te6edf3usbManagerLazyTb4b4b4.Te6edf3valueTff7b72!!

Tff7b72val Te6edf3usbDeviceConnection Tff7b72= Te6edf3usbManagerTb4b4b4.Te6edf3openDeviceTb4b4b4(Te6edf3deviceTb4b4b4.Te6edf3deviceTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3usbDeviceConnection Tff7b72=Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{

Te6edf3listenerTb4b4b4.Te6edf3onMissingPermissionTb4b4b4(Tb4b4b4)

Te6edf3closedTb4b4b4.Te6edf3setTb4b4b4(Tff7b72trueTb4b4b4)

Tff7b72return

Tb4b4b4}

Te6edf3portTb4b4b4.Te6edf3openTb4b4b4(Te6edf3usbDeviceConnectionTb4b4b4)

Te6edf3portTb4b4b4.Te6edf3setParametersTb4b4b4(T79c0ff1T79c0ff1T79c0ff5T79c0ff2T79c0ff0T79c0ff0Tb4b4b4, Te6edf3UsbSerialPortTb4b4b4.Te6edf3DATABITS_8Tb4b4b4, Te6edf3UsbSerialPortTb4b4b4.Te6edf3STOPBITS_1Tb4b4b4, Te6edf3UsbSerialPortTb4b4b4.Te6edf3PARITY_NONETb4b4b4)

T8b949e// Assert DTR/RTS so native USB-CDC firmware (RAK4631 / nRF52840) recognizes the host as

T8b949e// present and starts its serial-side Meshtastic protocol. Empirically, omitting these

T8b949e// signals causes the firmware to never respond to WAKE_BYTES, stalling the handshake at

T8b949e// Stage 1. Bridge-chip boards (CH340, CP210x, FTDI) tolerate the assertion.

Te6edf3portTb4b4b4.Te6edf3dtr Tff7b72= Tff7b72true

Te6edf3portTb4b4b4.Te6edf3rts Tff7b72= Tff7b72true

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffStarting serial reader threadTa5d6ff" Tb4b4b4}

Tff7b72val Te6edf3io Tff7b72=

Te6edf3SerialInputOutputManagerTb4b4b4(

Te6edf3portTb4b4b4,

Tff7b72object Tb4b4b4: T56d364SerialInputOutputManagerTb4b4b4.Te6edf3Listener Tb4b4b4{

Tff7b72override Tff7b72fun Td2a8ffonNewDataTb4b4b4(Te6edf3dataTb4b4b4: Te6edf3ByteArrayTb4b4b4) Tb4b4b4{

Te6edf3listenerTb4b4b4.Te6edf3onDataReceivedTb4b4b4(Te6edf3dataTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffonRunErrorTb4b4b4(Te6edf3eTb4b4b4: Te6edf3Exception?Tb4b4b4) Tb4b4b4{

Te6edf3closedTb4b4b4.Te6edf3setTb4b4b4(Tff7b72trueTb4b4b4)

T8b949e// Connection is already failing, don't try to set DTR/RTS as it will just throw more

T8b949e// IOExceptions

Te6edf3ignoreExceptionTb4b4b4(Te6edf3silent Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4{ Te6edf3portTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4) Tb4b4b4}

Te6edf3closedLatchTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)

Te6edf3listenerTb4b4b4.Te6edf3onDisconnectedTb4b4b4(Te6edf3eTb4b4b4)

Tb4b4b4}

Tb4b4b4}Tb4b4b4,

Tb4b4b4)

Tb4b4b4.Te6edf3apply Tb4b4b4{

Te6edf3readTimeout Tff7b72= T79c0ff2T79c0ff0T79c0ff0 T8b949e// To save battery we only timeout ever so often

Te6edf3ioRefTb4b4b4.Te6edf3setTb4b4b4(Tff7b72thisTb4b4b4)

Tb4b4b4}

Te6edf3ioTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)

Te6edf3listenerTb4b4b4.Te6edf3onConnectedTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tb4b4b4}